home *** CD-ROM | disk | FTP | other *** search
/ Windows Expert / Windows Expert.iso / windownt / queue.zip / QUEUE / QCLIENT.C < prev    next >
C/C++ Source or Header  |  1992-10-10  |  3KB  |  115 lines
  1. /************************************************************************\
  2. * The enclosed files, "the software," is provided by 
  3. * Microsoft Corporation "as is" without warranty of any kind. 
  4. * MICROSOFT DISCLAIMS ALL WARRANTIES, EITHER EXPRESS OR IMPLIED, 
  5. * INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES OF MERCHANTABILITY 
  6. * AND FITNESS FOR A PARTICULAR PURPOSE.  You assume all risks of 
  7. * using the software.
  8. * 
  9. * The software is Copyright (c) 1992 Microsoft Corporation.
  10. * Original Author: John M. Hall, Microsoft SDE  9/1/92
  11. *
  12. * You are granted the right to freely distribute this software.
  13. * You are granted the right to make changes provided this comment block
  14. * is retained without modification and you acknowledge the changes.
  15. * 
  16. \************************************************************************/
  17. #define DEBUG
  18. #include <stdio.h>
  19. #include <assert.h>
  20. #include <windows.h>
  21. #include <string.h>
  22. #include <queue.h>
  23. #include <shrmem.h>
  24. #include <myopt.h>
  25.  
  26. #define QUEUE_NAME "\\queues\\test"
  27.  
  28. #define TEST_MSGS     5
  29. #define TEST_DELAY  400
  30.  
  31. struct _write_test {
  32.     DWORD  dwEventCode;
  33.     DWORD  dwPriority;
  34.     LPTSTR lptstr;
  35. } test[TEST_MSGS] =
  36.     {
  37.      0,  0, "Terminate Processing",
  38.     11,  1, "First message sent",
  39.     12, 10, "Second message sent",
  40.     13,  5, "Third test msg",
  41.     14,  8, "Fourth"
  42.     };
  43.  
  44. void do_it(HQUEUE hq, int ii)
  45. {
  46.     DWORD   dwShrHandle;
  47.     LPTSTR  lptstr;
  48.  
  49.     dwShrHandle = ShrAlloc( 1000, 0);
  50.     lptstr = (LPTSTR) ShrLock(dwShrHandle);
  51.     strcpy( lptstr, test[ii].lptstr);
  52.     ShrUnlock(dwShrHandle);
  53.     printf( "Writing %d %d %d\n", test[ii].dwEventCode,
  54.             dwShrHandle, test[ii].dwPriority);
  55.     WriteQueue(hq, test[ii].dwEventCode, dwShrHandle, test[ii].dwPriority);
  56.     Sleep(TEST_DELAY);
  57.  
  58. }
  59.  
  60. main(int argc, char *argv[])
  61. {
  62.     HQUEUE  hq;
  63.     DWORD   dwErr;
  64.     DWORD   dwOwner;
  65.     int     ii;
  66.     HANDLE  hClient;
  67.     BOOL    bWait = FALSE;
  68.     int     iFlag;
  69.  
  70.  
  71.     while (iFlag = my_getopt( argc, argv, "w"))
  72.         {
  73.         switch(iFlag)
  74.             {
  75.             case 'w':
  76.                 bWait = TRUE;
  77.                 break;
  78.             default:
  79.                 printf( "Unidentified flag %c\n", (char) iFlag);
  80.                 break;
  81.             }
  82.         }
  83.  
  84.  
  85.  
  86.     if (bWait)
  87.         hClient = CreateEvent( NULL, TRUE, FALSE, "ClientSaysGo");
  88.  
  89.     dwErr = OpenQueue( &dwOwner, &hq, QUEUE_NAME);
  90.  
  91.     if (dwErr != 0)
  92.         {
  93.         printf( "CreateQueue Failed\n");
  94.         return(-1);
  95.         }
  96.  
  97.     printf( "Queue owner is %d\n", dwOwner);
  98.  
  99.  
  100.     for (ii = 1; ii < TEST_MSGS; ii++)
  101.         {
  102.         do_it(hq, ii);
  103.         }
  104.  
  105.     if (bWait)
  106.         SetEvent(hClient);
  107.  
  108.     do_it(hq, 0);
  109.  
  110.     printf( "Client exiting\n");
  111.     CloseQueue(hq);
  112.  
  113.     return(0);
  114. }
  115.